package com.learn.multi_thread.A_BaseThread.E_ProductionOfConsumers.B_BlockQueueImplementation;

import java.util.concurrent.ArrayBlockingQueue;

public class BlockQueueCookThread {
    /**
     * 需求： 利用阻塞队列完成生产者消费者（等待唤醒机制）的代码
     * 注意： 生产和消费者必须使用同一个阻塞队列
     * @param args
     */
    public static void main(String[] args) {
        ArrayBlockingQueue<String> quere = new ArrayBlockingQueue<>(1);

        ProductOfCook productOfCook = new ProductOfCook(quere);
        ConsumerOfCook consumerOfCook = new ConsumerOfCook(quere);

        productOfCook.start();
        consumerOfCook.start();
    }
}
